//! Kafka 适配器编译测试
//! 
//! 这个文件用于独立测试 Kafka 适配器是否可以正常编译和使用

use rustcloud_bus::kafka_adapter::{KafkaMessageBus, KafkaAdapterConfig};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🧪 Kafka 适配器编译测试开始");

    // 测试默认配置创建
    let _config = KafkaAdapterConfig::default();
    println!("✅ KafkaAdapterConfig 默认配置创建成功");

    // 测试自定义配置
    let custom_config = KafkaAdapterConfig {
        bootstrap_servers: "localhost:9092".to_string(),
        group_id: "test_group".to_string(),
        client_id: "test_client".to_string(),
        ..Default::default()
    };
    println!("✅ KafkaAdapterConfig 自定义配置创建成功");

    // 尝试创建消息总线（这里可能会失败，因为没有 Kafka 服务器）
    match KafkaMessageBus::with_config(custom_config).await {
        Ok(_bus) => {
            println!("✅ KafkaMessageBus 创建成功");
        }
        Err(e) => {
            println!("⚠️  KafkaMessageBus 创建失败（预期，因为没有 Kafka 服务器）: {}", e);
        }
    }

    println!("🎉 Kafka 适配器编译测试完成");
    Ok(())
}